Skip to content

add stateful subscriber feature#833

Closed
DavidBadura wants to merge 2 commits into
3.20.xfrom
inline-projection
Closed

add stateful subscriber feature#833
DavidBadura wants to merge 2 commits into
3.20.xfrom
inline-projection

Conversation

@DavidBadura

@DavidBadura DavidBadura commented Mar 29, 2026

Copy link
Copy Markdown
Member

No description provided.

@DavidBadura
DavidBadura marked this pull request as draft April 1, 2026 13:34
@DavidBadura
DavidBadura force-pushed the inline-projection branch 2 times, most recently from 024fdfa to 183e754 Compare April 15, 2026 19:52
@github-actions

github-actions Bot commented Apr 15, 2026 •
edited
Loading

Copy link
Copy Markdown

Hello 👋

here is the most recent benchmark result: 

SimpleSetupBench
================

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.113ms (±0.00%)   | 1.144ms (±0.00%)   | -2.67%    | 35.044mb        | 35.562mb   | -1.45%      |
| benchLoad10000Events ()                | 65.352ms (±0.00%)  | 65.343ms (±0.00%)  | +0.01%    | 35.044mb        | 35.044mb   | 0.00%       |
| benchSave1Event ()                     | 1.266ms (±0.00%)   | 1.203ms (±0.00%)   | +5.19%    | 35.044mb        | 35.044mb   | 0.00%       |
| benchSave10000Events ()                | 240.945ms (±0.00%) | 242.544ms (±0.00%) | -0.66%    | 35.044mb        | 35.044mb   | 0.00%       |
| benchSave10000Aggregates ()            | 8.385s (±0.00%)    | 8.484s (±0.00%)    | -1.17%    | 35.044mb        | 35.044mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 5.307s (±0.00%)    | 5.296s (±0.00%)    | +0.20%    | 35.044mb        | 35.044mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

NoopSubscriptionEngineBench
===========================

+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                                   | memory                                     |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 82.943ms (±0.00%) | 83.711ms (±0.00%) | -0.92%    | 47.560mb        | 47.560mb   | 0.00%       |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

SnapshotsBench
==============

+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                   | memory                                     |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchLoad10000EventsMissingSnapshot () | 67.583ms (±0.00%) | 63.284ms (±0.00%) | +6.79%    | 35.049mb        | 35.049mb   | 0.00%       |
| benchLoad10000Events ()                | 1.320ms (±0.00%)  | 1.326ms (±0.00%)  | -0.45%    | 35.049mb        | 35.049mb   | 0.00%       |
+----------------------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

CommandToQueryBench
===================

+----------------+------------------+------------------+-----------+-----------------+------------+-------------+
|                | time (kde mode)                                 | memory                                     |
+----------------+------------------+------------------+-----------+-----------------+------------+-------------+
| subject        | Tag: <current>   | Tag: base        | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------+------------------+------------------+-----------+-----------------+------------+-------------+
| benchCreate () | 3.050ms (±0.00%) | 2.876ms (±0.00%) | +6.02%    | 4.896mb         | 4.896mb    | 0.00%       |
| benchUpdate () | 4.521ms (±0.00%) | 4.707ms (±0.00%) | -3.95%    | 5.031mb         | 5.031mb    | 0.00%       |
| benchBoth ()   | 6.836ms (±0.00%) | 6.879ms (±0.00%) | -0.62%    | 4.883mb         | 4.877mb    | +0.13%      |
+----------------+------------------+------------------+-----------+-----------------+------------+-------------+

SplitStreamBench
================

+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                         | time (kde mode)                                     | memory                                     |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                 | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad10000Events () | 5.649ms (±0.00%)   | 5.654ms (±0.00%)   | -0.10%    | 35.649mb        | 35.649mb   | 0.00%       |
| benchSave10000Events () | 356.606ms (±0.00%) | 354.646ms (±0.00%) | +0.55%    | 35.652mb        | 35.651mb   | +0.00%      |
+-------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

SubscriptionEngineBench
=======================

+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                               | memory                                     |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>  | Tag: base       | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 3.356s (±0.00%) | 3.368s (±0.00%) | -0.35%    | 47.560mb        | 47.560mb   | 0.00%       |
+---------------------------+-----------------+-----------------+-----------+-----------------+------------+-------------+

SimpleSetupStreamStoreBench
===========================

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.150ms (±0.00%)   | 1.130ms (±0.00%)   | +1.71%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchLoad10000Events ()                | 71.254ms (±0.00%)  | 70.770ms (±0.00%)  | +0.68%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave1Event ()                     | 1.332ms (±0.00%)   | 1.229ms (±0.00%)   | +8.39%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave10000Events ()                | 304.726ms (±0.00%) | 304.560ms (±0.00%) | +0.05%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave10000Aggregates ()            | 8.493s (±0.00%)    | 8.578s (±0.00%)    | -0.99%    | 35.206mb        | 35.206mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 5.507s (±0.00%)    | 5.490s (±0.00%)    | +0.31%    | 35.206mb        | 35.206mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

SubscriptionEngineBatchBench
============================

+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
|                           | time (kde mode)                                   | memory                                     |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| subject                   | Tag: <current>    | Tag: base         | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+
| benchHandle10000Events () | 83.558ms (±0.00%) | 84.095ms (±0.00%) | -0.64%    | 35.544mb        | 35.544mb   | 0.00%       |
+---------------------------+-------------------+-------------------+-----------+-----------------+------------+-------------+

PersonalDataBench
=================

+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
|                                        | time (kde mode)                                     | memory                                     |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| subject                                | Tag: <current>     | Tag: base          | time-diff | Tag: <current>  | Tag: base  | memory-diff |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+
| benchLoad1Event ()                     | 1.230ms (±0.00%)   | 1.266ms (±0.00%)   | -2.87%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchLoad10000Events ()                | 99.899ms (±0.00%)  | 100.389ms (±0.00%) | -0.49%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchSave1Event ()                     | 1.813ms (±0.00%)   | 1.879ms (±0.00%)   | -3.54%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchSave10000Events ()                | 264.695ms (±0.00%) | 267.917ms (±0.00%) | -1.20%    | 35.586mb        | 35.586mb   | 0.00%       |
| benchSave10000Aggregates ()            | 12.880s (±0.00%)   | 12.927s (±0.00%)   | -0.36%    | 35.585mb        | 35.585mb   | 0.00%       |
| benchSave10000AggregatesTransaction () | 9.788s (±0.00%)    | 9.793s (±0.00%)    | -0.05%    | 36.044mb        | 36.044mb   | 0.00%       |
+----------------------------------------+--------------------+--------------------+-----------+-----------------+------------+-------------+

This comment gets update everytime a new commit comes in!

@DavidBadura DavidBadura added the enhancement New feature or request label Apr 16, 2026
@DavidBadura DavidBadura changed the title add inline projection feature add stateful subscriber feature Apr 16, 2026
@DavidBadura
DavidBadura marked this pull request as ready for review April 16, 2026 09:12
@DanielBadura
DanielBadura changed the base branch from 3.19.x to 3.20.x April 16, 2026 09:48
@DavidBadura DavidBadura added this to the 3.20.0 milestone May 21, 2026
@DavidBadura DavidBadura removed this from the 3.20.0 milestone Jun 30, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Reviewers

No reviews

Assignees

No one assigned

Labels

enhancement New feature or request

Projects

None yet

Milestone

No milestone

Development

Successfully merging this pull request may close these issues.

1 participant

@DavidBadura